package com.ynet.middleground.riskmanage.mq;

import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;
import org.springframework.stereotype.Component;

/**
 * @Author zhangyongbin
 **/
public interface SourceBlchzt {

    /**
     * 风控中心主动推送出入池状态数据（风控中心-->全球捷运）
     */
    String JKZTFK_TO_QQJY_BLCHZT_PUSH = "jkztfk_to_qqjy_blchzt_push";


    /**
     * 风控中心主动推送入池状态数据（风控中心-->全球捷运）
     *
     * @return
     */
    @Output(SourceBlchzt.JKZTFK_TO_QQJY_BLCHZT_PUSH)
    MessageChannel blchztNotice();


    /**
     * 以下代码测试使用
     */
    /**
     * 模拟核心发送数据
     */
    String BLXD_TO_JKZTFK_BLCHZT_PUSH = "blxd_to_jkztfk_blchzt_push";


    @Output(SourceBlchzt.BLXD_TO_JKZTFK_BLCHZT_PUSH)
    MessageChannel notice();



}
